22c36ff1c6238bfb1b1386612ef17cb50ad68bb9,spi/backups/src/main/java/CounterService.java,CounterService,rollbackMigration,#PartitionMigrationEvent#,80
Before Change
@Override
public void rollbackMigration(PartitionMigrationEvent event) {
if (event.getMigrationEndpoint() == MigrationEndpoint.DESTINATION) {
Container container = containers[event.getPartitionId()];
container.clear();
}
}
After Change
public void rollbackMigration(PartitionMigrationEvent event) {
if (event.getMigrationEndpoint() == MigrationEndpoint.DESTINATION) {
int currentReplicaIndex = event.getCurrentReplicaIndex();
if (currentReplicaIndex == -1 || currentReplicaIndex > 1) {
clearPartitionReplica(event.getPartitionId());
}
}
}